7af7a55ede0cba513836032ff7f12be46b316633,spring-web-reactive/src/main/java/org/springframework/http/codec/json/JacksonJsonEncoder.java,JacksonJsonEncoder,encode,#Publisher#DataBufferFactory#ResolvableType#MimeType#Object#,72
Before Change
Flux<DataBuffer> arraySeparators =
Mono.fromSupplier(() -> bufferFactory.wrap(SEPARATOR_BUFFER)).repeat();
Mono<DataBuffer> endArray =
Mono.just(bufferFactory.wrap(END_ARRAY_BUFFER));
Flux<DataBuffer> serializedObjects = Flux.from(inputStream)
.map(value -> serialize(value, bufferFactory, elementType));
After Change
bufferFactory.wrap(SEPARATOR_BUFFER)));
return Flux.concat(Mono.just(bufferFactory.wrap(START_ARRAY_BUFFER)), array.skipLast(1),
Mono.just(bufferFactory.wrap(END_ARRAY_BUFFER)));
}
private DataBuffer encodeValue(Object value, DataBufferFactory bufferFactory, ResolvableType type) {